package com.aotain.jupiter.flink;

import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class SynFloodFlinkTest {

	public static void main(String[] args ) {
		
		StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
		
		DataStream<Tuple2<String,String>> dataStream = env.readTextFile("")
				.flatMap(new SynFloodStat());
	}
	
	
}
